package main

import (
	"encoding/json"
	"log"
	"os"
	"yunpan/config"
	"yunpan/mq"
)

func ProcessTransfer(msg []byte) bool{
	//解析msg
	pubData := mq.TransferData{}
	err:= json.Unmarshal(msg,pubData)
	if err != nil{
		log.Println(err.Error())
		return false
	}
	//根据临时存储文件路径，创建文件句柄
	// filed,err := os.Open(pubData.DestLocation)
	_,err = os.Open(pubData.DestLocation)
	if err != nil{
		log.Println(err.Error())
		return false
	}
	//通过文件句柄将文件读出来上传到ceph
	//更新文件的存储路径到文件表
	return true
}


func main(){
	log.Println("开始监听转移任务队列")
	mq.StartConsume(config.TransCephQueueName,"transfer_ceph",ProcessTransfer)
}